/**
 * 版权所有(C)，上海***股份有限公司，2018，所有权利保留。
 * 
 * 项目名：	rabbitmq
 * 文件名：	Producer.java
 * 模块说明：	
 * 修改历史：
 * 2018年9月28日 - Administrator - 创建。
 */
package com.study.rabbitmq.routing;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.study.rabbitmq.util.ConnectionUtil;
import com.study.rabbitmq.util.QueueUtil;

/**
 * @author Administrator
 *
 */
public class Producer {
  public static void main(String[] argv) throws Exception {
    // 获取到连接以及mq通道
    Connection connection = ConnectionUtil.getConnection();
    Channel channel = connection.createChannel();
    // 声明exchange
    channel.exchangeDeclare(QueueUtil.EXCHANGE_NAME_ROUTING, "direct");
    // 消息内容
    String message = "Hello World!";
    // 发送一个routingKey为delete的消息
    channel.basicPublish(QueueUtil.EXCHANGE_NAME_ROUTING, "delete", null, message.getBytes());
    channel.close();
    connection.close();
  }
}
